package(default_visibility = ["//visibility:public"])

py_library(
    name = "kafka_querier",
    srcs = [
        "logic/kafka_querier.py",
    ],
    deps = [
        "//python/coin/tool/strat_monitor/util:monitor_util",
        "//python/coin/util/queue:queue",
    ]
)
